818acb3cecb98a3823711a73637107f224a9e8c1,cdap-data-fabric/src/main/java/co/cask/cdap/data/stream/service/ConcurrentStreamWriter.java,StreamFileFactory,create,#Id.Stream#,313

Before Change


    FileWriter<StreamEvent> create(Id.Stream streamId) throws IOException {
      StreamConfig streamConfig = streamAdmin.getConfig(streamId);
      Integer generation = generations.get(streamId);
      if (generation == null) {
        generation = StreamUtils.getGeneration(streamConfig);
      }

      LOG.info("Create stream writer for {} with generation {}", streamId, generation);

After Change


     */
    FileWriter<StreamEvent> create(Id.Stream streamId) throws IOException {
      StreamConfig streamConfig = streamAdmin.getConfig(streamId);
      int generation = StreamUtils.getGeneration(streamConfig);

      LOG.info("Create stream writer for {} with generation {}", streamId, generation);
      return writerFactory.create(streamConfig, generation);